package com.kaizige.realtor.Dao;

import com.kaizige.realtor.Pojo.message;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.web.reactive.WebFluxProperties;
import org.springframework.boot.web.servlet.server.Session;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import javax.servlet.http.HttpSession;
import java.util.List;
import java.util.Map;

@Repository
public class messageDao {
	@Autowired
	JdbcTemplate jdbcTemplate;
	
	//房主给中介发送房屋状态变更消息
	public void ownToManUp(message msg){
		String sql = "insert into message values(?,?,?,?,?,?,?)";
		Object[] args = {msg.getId(),msg.getFrom(),msg.getFrom_iden(),msg.getTo(),
				msg.getTo_iden(),msg.getContent(),0};
		jdbcTemplate.update(sql,args);
	}
	//租客给中介发送申请看房消息
	public void tenToManSeeHou(message msg){
		String sql = "insert into message values(?,?,?,?,?,?,?)";
		Object[] args = {msg.getId(),msg.getFrom(),msg.getFrom_iden(),msg.getTo(),
				msg.getTo_iden(),msg.getContent(),0};
		jdbcTemplate.update(sql,args);
	}
	
	// 根据用户信息获取收发件
	// 获取收到信息
	public List<Map<String,Object>> getToMes(String user){
		String sql = "select * from message where `to`=?";
		List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql, user);
		return maps;
	}
	
	// 获取发出过的信息
	public List<Map<String,Object>> getFromMes(String user){
		String sql = "select * from message where `from`=?";
		List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql, user);
		return maps;
	}
	
	//修改收件的状态
	public void setMsgSta(int id){
		String sql = "update message set msg_status=1 where id=?";
		jdbcTemplate.update(sql,id);
	}
}
